// 导入mysql
const mysql = require("mysql");

// 创建连接
const conn = mysql.createConnection({
	host:"localhost", //域名
	user:"root", // 用户名
	password:"", // 密码
	database:"feed" //数据库
})
// 连接数据
conn.connect(function(err){
	if(!err){
		console.log("连接数据库成功")
	}else{
		console.log(err)
	}
})

// 关闭数据库
/* conn.end(function(err){
	if(!err){
		console.log("数据库已经断开")
	}
}) */

// ======================创建服务器
// 导入http 服务
const http = require("http");
// 创建服务
// 导入url解析工具
const url = require("url");
const server = http.createServer(function(req,res){
	// req请求的数据；res响应的数据
	// 设置响应吗是200
	res.statusCode = 200;
	// 设置响应头(返回前端的是json格式)
	res.setHeader("Content-Type","application/json")
	// 允许前端跨域请求
	res.setHeader("Access-Control-Allow-Origin","*");
	// 解析请求的url
	var urlObj = url.parse(req.url);
	// 拿到查询条件
	var obj = {current:1};
	if(urlObj.query){
		// 按&分割
		var query = urlObj.query.split("&");
		// 对数组进行遍历
		for(var i=0;i<query.length;i++){
			// 数组每个元素按等分割
			var temp = query[i].split("=");
			// 获取对象键和值
			obj[temp[0]] =temp[1]
		}
		// console.log(obj);
	}
	
	
	// 定义sql语句（每次取2条数据  current=1  偏移0  current 2 偏移2  current3 偏移4）
	var sql = `select * from feedback where 1 limit ${(obj.current*1-1)*2}, 2`;
	// console.log(sql);
	// 执行sql语句 result是数据库返回的数据
	conn.query(sql,function(err,result){
		if(!err){
			res.end(JSON.stringify(result))
		}else{
			res.end(`{"code":1,"msg":"数据库错误"}`)
		}
		/* conn.end(function(err){
			if(!err){
				console.log("数据库已经断开")
			}else{
				console.log(err);
			}
		}) */
	})
})

// 监听端口启动服务器
server.listen(8888,function(){
	console.log("服务器","localhost:8888","启动成功");
})